はじめに

デバイスとセンサーはThings Cloudに接続できます。デバイスのインターフェース および MQTT デバイス インテグレーションを参照してください。

センサーは Things Cloud の Measurement または Event オブジェクトを生成し、デバイスは Things Cloud プラットフォーム内で作成された Operation オブジェクトを受け取ることができます。これらのオブジェクト(MeasurementEventOperation)はすべて Things Cloud プラットフォーム内の単一のデバイスに関連付けられます。デバイスには複数のタイプのメジャーメントが関連付けられている場合があり、各デバイスがサポートするメジャーメントのタイプは、他のデバイスと同じである場合もあれば、他のデバイスと異なる場合もあります。デバイスが Things Cloud に接続されると、これらのデバイスに関する情報が Things Cloud インベントリに保存されます。これらはデバイス管理アプリケーションで表示され、そのデバイスに関連付けられた MeasurementEvent または Operation オブジェクトを表示するために使用することもできます。詳細については、デバイスの管理と接続を参照してください。

ストリーミング分析アプリケーションを使用すると、独自のロジックを IoT ソリューションに追加して、デバイスまたは他のデータソースから受信したデータを即座に処理できます。これらのユーザー定義の操作は、例えば、新しい受信データについてアプリケーションに警告したり、受信したデータに基づいて新しい操作を作成したり(センサーのしきい値を超えたときにアラームを送信するなど)、デバイス上で操作をトリガーしたりできます。

典型的なリアルタイム分析のユースケースは次の通りです。

  • リモート制御: 温度が40度を超えて上昇した場合、デバイスの電源を切る
  • 検証: 負のメーター読み取り値または前よりも低いメーター読み取り値を破棄する
  • 派生データ: 自動販売機 1 台当たりの1日あたりの販売取引量を算出する
  • 集計: 顧客の 1 日当たりの自動販売機の売上を合計する
  • 通知: 保有する機械の 1 つに停電が発生した場合、メールを送信する
  • 圧縮: すべての車の位置の更新を 5 分ごとにのみ保存する(ただし、ユーザーインターフェースに表示している車のリアルタイムデータは送信する)

Things Cloud プラットフォームには、Things Cloud プラットフォームによって管理され(手動で開始または停止されません)、Things Cloud と通信するよう事前に構成された Apama コリレーターコンポーネントが含まれています。このコリレーターは、Analytics Builder ランタイムをホストし、EPL アプリを使用して追加された操作ロジックも実行します。 操作ロジックは、Apama のイベント処理言語(Apama EPL)に基づいています。

ストリーミング分析アプリケーションは、Things Cloud Core (cloud) と Things Cloud Edge (local installation) の両方で使用できます。

ホーム画面

ストリーミング分析アプリケーションのホーム画面にアクセスするには、アプリケーションスイッチャー内の ストリーミング分析 アイコン をクリックします。

ストリーミング分析 ホーム画面

ストリーミング分析アプリケーションのホーム画面では、アプリケーションのさまざまなページに移動できます。これらは、分析ビルダーEPL アプリ です。これらのページには、ホーム画面の対応する 開く ボタンを使用するか、左側のナビゲータを使用してアクセスできます。

ページにさらに多くのスペースが必要な場合は、ナビゲータを非表示にすることができます。 トップバーの左端にある小さな矢印をクリックしてナビゲータの表示を切り替えます。

ホーム画面には、スマートルールに関する情報も表示されます。スマートルールの作成と管理は、コックピット アプリケーションで行います。詳細については、スマートルールを参照してください。

ホーム画面とナビゲータには、使用が許可されている項目のエントリのみが表示されます。 テナントが登録している Apama-ctrl マイクロサービスのバージョンに応じて異なります。マイクロサービスのランタイムとアプリケーション および ストリーミング分析アプリケーションのホーム画面のカスタマイズを参照してください。

分析ビルダー

ストリーミング分析アプリケーションの ストリーミング分析 ページを使用すると、新しいデータを生成したりイベントを出力したりするためにストリーミング データを変換または分析する分析モデルを構築できます。モデルは、リアルタイムでデータを処理できます。

モデルは、デバイスやセンサーのメジャーメントとやり取りします。モデルはデバイスから Measurement オブジェクトと Event オブジェクトを受け取ることができ、これらはモデル内で実行される計算やパターン検出への入力を提供します。モデルは、センサーから導出された値(平均気温など)を表す新しい Measurement オブジェクトを作成したり、メジャーメントを他の分析モデルへの入力として使用したりできます(モデル間の接続)。モデルは、デバイスに送信される新しい Operation オブジェクトを作成して、デバイスを制御できます(例えば、警報ベルを鳴らす、画面にメッセージを表示する、デバイスのスイッチをオフにするなど)。モデルは Things Cloud インベントリにも保存されますが、モデルマネージャーを介してアップロードまたはダウンロードできます。

事前に構築された「ブロック」を「モデル」に結合することにより、グラフィカルな環境でモデルを構築します。モデル内のブロックはロジックをパッケージ化しており、多数の入力、出力、パラメーターを持っています。各ブロックは、センサーからのデータの受信、計算の実行、条件の検出、出力信号の生成など、特定の機能を実装します。ブロックの構成を定義し、「ワイヤー」を使用してブロックを接続します。モデルを編集したり、履歴データを使用して展開をシミュレートしたり、ライブシステムに対して実行したりできます。詳細については、分析ビルダーを参照してください。

分析ビルダーで提供されるブロックが必要なロジックを実装していない場合は、カスタムブロックを構築することもできます。詳細については、独自のブロックの作成を参照してください。

さまざまなテナントオプションを設定することで、Analytics Builderのいくつかの側面をカスタマイズできます。 詳細については、構成 を参照してください。

EPLアプリ

ストリーミング分析アプリケーションの EPL アプリ ページでは、Apama のイベント処理言語(Apama EPL)でビジネス ロジックを作成できます。これにより、テキストベースのプログラミング言語の機能と柔軟性が向上します。これは、より複雑なロジックが必要な場合、またはロジックが分析モデルのパターンに適合しない場合の代替手段です。

Apama EPL で記述された EPL アプリ(つまり、単一の *.mon ファイル)を Things Cloud 内で直接開発することができます。既存の *.mon ファイルを EPL アプリとして Things Cloud にインポートすることもできます。ストリーミング分析アプリケーションから EPL アプリをアクティブ化する場合は、それを Things Cloud にデプロイします。例を含む詳細情報については、EPLアプリを参照してください。

簡単に始める方法は、EPL エディターからアクセスできる EPL サンプルのコードを調べることです。EPL アプリの作成方法とサンプルへのアクセス方法については、ストリーミング分析アプリケーションを使用したアプリの開発を参照してください。まず、「計測値のしきい値超過時アラームを作成」など、温度測定を含む単純なサンプルの 1 つを使用します。このサンプルを使用すると、すぐに結果を確認できます。独自の EPL コードをサンプルに追加し、変更を試してみてください。

Things Cloud と対話するには、Apama API を使用します。詳細については、EPL の API リファレンス(ApamaDoc)com.apama.cumulocity パッケージを参照してください。これは Apama ドキュメントの一部です。 

前提条件

ブラウザ

ストリーミング分析アプリケーションは、Things Cloud と同じブラウザをサポートしますが、次の例外があります。スマートフォンとタブレットのブラウザはサポートされていません。

権限

分析ビルダーを使用するには、少なくとも次の権限が必要です。

権限タイプ 権限レベル
CEP管理 管理者
オプション管理 読み取り
インベントリ 読み取り

これは通常、これらの権限を持つグローバルロールを使用し、そのロールが分析ビルダー アプリケーションにアクセスできるようにすることで実現されます。詳細については、権限の管理を参照してください。

EPL アプリを使用するには、次の権限のみが必要です。

権限タイプ 権限レベル
CEP管理 管理者

マイクロサービスのランタイムとアプリケーション

分析モデル、EPL アプリ、スマートルールは、Apama-ctrl マイクロサービスで実行されます。すべてのマイクロサービスには、事前構成されたリソース制限(CPU やメモリなど)が設定されています。 分析モデル、EPL アプリ、スマートルールのリソース使用量は、アプリケーションの複雑さ、デバイス数など、さまざまな要因によって異なります。メモリ不足の問題を回避するために、お客様はアプリケーションをプロファイリングすることをお勧めします。

次を行うには 次のものが必要
分析モデルの構築 Apama-ctrl マイクロサービス バリアント(Apama-ctrl-starter など)と
ストリーミング分析アプリケーション
EPL アプリの開発 Apama-ctrl マイクロサービス バリアント(Apama-ctrl-250mc-1g など)と
ストリーミング分析アプリケーション
スマートルールの使用 任意の Apama-ctrl マイクロサービス バリアントと
スマートルール マイクロサービス(Things Cloudの標準テナント(サブテナント)に含まれます)

次のセクションも参照してください。

テナントに Apama-ctrl-starter マイクロサービスが登録されている場合、次のことが適用されます。

  • アクティブな分析モデル数は最大 3 つに制限されます。Analytics Builder Block SDKで作成されたカスタムブロックは使用できません。
  • EPL アプリページは、ストリーミング分析アプリケーションで使用できません。
  • スマートルールはサポートされています。

テナントに Apama-ctrl-250mc-1g マイクロサービス(ま​​たは、その大きなバリアントの 1 つ)が登録されている場合、次のことが適用されます。

  • 分析モデル、EPL アプリ、スマートルールがサポートされています。
  • Analytics Builder Block SDKで作成されたカスタムブロックが使用できます。

テナントに Apama-ctrl-mt-4c-16g マイクロサービスが登録されている場合、次のことが適用されます。

  • マルチテナント サポート
  • EPL アプリは、マイクロサービスを所有するテナントでのみ有効になり、サブテナントでは無効です。
  • 分析ビルダーページは、現在ストリーミング分析アプリケーションでは使用できません。
  • スマートルールはサポートされています。

テナントに Apama-ctrl-smartrules または Apama-ctrl-smartrulesmt マイクロサービスが登録されている場合、次のことが適用されます。

  • スマートルールはサポートされています。
  • 分析ビルダー および EPL アプリ ページは、ストリーミング分析アプリケーションで使用できません。

機能の追加については、製品サポートにお問い合わせください。

言語設定

ストリーミング分析アプリケーションのユーザーインターフェースが表示される言語は、Things Cloud のユーザー設定によって異なります。詳細については、ユーザーオプションと設定を参照してください。

Things Cloud またはブラウザが ストリーミング分析アプリケーションで現在サポートされていない言語に設定されている場合、ユーザーインターフェースはデフォルトの言語である英語で表示されます。